home *** CD-ROM | disk | FTP | other *** search
/ InfoMagic Internet Tools 1995 April / Internet Tools.iso / applic / ntp / depredated / ntp.3.4 / patches / patch13.Z / patch13
Encoding:
Text File  |  1991-09-29  |  52.4 KB  |  1,914 lines
  1. System: ntp version 3.4
  2. Patch #: 13
  3. Priority: medium
  4. From: louie@trantor.umd.edu
  5.  
  6. Description:
  7. A few cosmetic changes in ntp.c for the case when udp/ntp is not in the
  8. /etc/services file.
  9.  
  10. A few extra diddles in ntp.h for the reference clock feature.
  11.  
  12. A couple of changes to debug NeXT support in ntp_adjust.c
  13.  
  14. Changes for reference clock feature in ntp_proto.c
  15.  
  16. In ntp_sock.c, change the order that the bind() call is done for each socket.
  17. It turns out that if you have the Multicast code installed, incoming packets
  18. will be delived to the *first* socket that matches.  It also turns out that
  19. when binding sockets, the first one bound is the last on checked, so we want
  20. to bind the wildcard socket first.
  21.  
  22. Changes in ntpd.c for reference clock support.  Also, a few diddles to
  23. accomodate the NeXT computer system that has a slightly different nlist.h
  24.  
  25. A few cosmetic changes for ntpd.c
  26.  
  27. Added support few a new type of unsigned long to double compiler brokenness,
  28. called GENERIC_UNS_BUG.  If this is defined, then the unsigned long is
  29. shifted right one bit, the high-order bit of the result is cleared, then
  30. converted to a double.  The double is multiplied by 2.0, and the a 1.0 is
  31. optionall added to it if the low order bit of the original unsigned long
  32. was set.  Whew!
  33.  
  34. Add test for GENERIC_UNS_BUG to test.c
  35.  
  36. Repeat-By:
  37.  
  38. Fix:    From rn, say "| patch -p -N -d DIR", where DIR is your ntp source
  39.     directory.  Outside of rn, say "cd DIR; patch -p -N <thisarticle".
  40.     If you don't have the patch program, apply the following by hand,
  41.     or get patch (version 2.0, latest patchlevel).
  42.  
  43.     After patching:
  44.         make depend
  45.         make
  46.         make install
  47.  
  48.     If patch indicates that patchlevel is the wrong version, you may need
  49.     to apply one or more previous patches, or the patch may already
  50.     have been applied.  See the patchlevel.h file to find out what has or
  51.     has not been applied.  In any event, don't continue with the patch.
  52.  
  53.     If you are missing previous patches they can be obtained from me:
  54.  
  55.     Louis A. Mamakos
  56.     louie@trantor.umd.edu
  57.  
  58.     You can also get the patches via anonymous FTP from
  59.     trantor.umd.edu.
  60.  
  61. Index: patchlevel.h
  62. Prereq: 12
  63. 1c1
  64. < #define PATCHLEVEL 12
  65. ---
  66. > #define PATCHLEVEL 13
  67.  
  68. Index: Makefile
  69. *** Makefile.old    Thu May 18 18:37:56 1989
  70. --- Makefile    Thu May 18 18:37:59 1989
  71. ***************
  72. *** 1,6 ****
  73. ! # $Source: /usr/users/louie/ntp/RCS/Makefile,v $ $Revision: 3.4.1.6 $ $Date: 89/05/03 15:08:06 $
  74.   #
  75.   # $Log:    Makefile,v $
  76.   # Revision 3.4.1.6  89/05/03  15:08:06  louie
  77.   # In the Makefile, remove references to the readclock.c module.
  78.   # 
  79. --- 1,10 ----
  80. ! # $Source: /usr/users/louie/ntp/RCS/Makefile,v $ $Revision: 3.4.1.7 $ $Date: 89/05/18 12:43:32 $
  81.   #
  82.   # $Log:    Makefile,v $
  83. + # Revision 3.4.1.7  89/05/18  12:43:32  louie
  84. + # Add preliminary support of NeXT machine, new floating point bug work-around
  85. + # and reference clock support.
  86. + # 
  87.   # Revision 3.4.1.6  89/05/03  15:08:06  louie
  88.   # In the Makefile, remove references to the readclock.c module.
  89.   # 
  90. ***************
  91. *** 76,81 ****
  92. --- 80,87 ----
  93.   #    SETTICKADJ - attempt to modify kernel's `tickadj' variable at run time.
  94.   #    REFCLOCK  - define if you have a reference clock attached to your
  95.   #            machine.  (untested by UMD)
  96. + #    PSTI - define along with REFCLOCK if you have a PSTI clock attached
  97. + #        that you'd like to use a a reference clock.
  98.   #    XTAL=0 - for line freq clock, or
  99.   #    XTAL=1      for crystal controlled clock (default)
  100.   #    LOG_NTP=foo - to change the syslog facility.  You could specify
  101. ***************
  102. *** 84,91 ****
  103.   #    NOSWAP - allow use of plock() to prevent swapping
  104.   #
  105.   
  106. ! # FEATURES=
  107. ! FEATURES= -DBROADCAST_NTP -DSETTICKADJ -DDEBUG
  108.   
  109.   # for 4.3 BSD
  110.   DEFINES=
  111. --- 90,98 ----
  112.   #    NOSWAP - allow use of plock() to prevent swapping
  113.   #
  114.   
  115. ! #FEATURES= -DBROADCAST_NTP -DSETTICKADJ -DDEBUG
  116. ! #FEATURES= -DSETTICKADJ -DDEBUG -DREFCLOCK -DPSTI
  117. ! FEATURES= -DSETTICKADJ -DDEBUG -DREFCLOCK
  118.   
  119.   # for 4.3 BSD
  120.   DEFINES=
  121. ***************
  122. *** 93,105 ****
  123.   # for Sun
  124.   #DEFINES= -DSUN_FLT_BUG
  125.   
  126. ! # for Ultrix 2.0/2.2/3.0
  127.   # don't forget to fix the broken definition of inet_addr in netdb.h
  128.   # it should be declared as a u_long not a in_addr  (the doc is wrong also)
  129. ! # (Note 3.0 has it fixed).  VAX_COMPILER_FLT_BUG is defined for pcc which
  130. ! # doesn't know how to convert an unsigned long into a float/double
  131.   #DEFINES= -DVAX_COMPILER_FLT_BUG -DNOSWAP
  132.   
  133.   CFLAGS= -O ${DEFINES} ${FEATURES} ${INCPATH}
  134.   #
  135.   # Header files
  136. --- 100,116 ----
  137.   # for Sun
  138.   #DEFINES= -DSUN_FLT_BUG
  139.   
  140. ! # for Ultrix 2.0/2.2
  141.   # don't forget to fix the broken definition of inet_addr in netdb.h
  142.   # it should be declared as a u_long not a in_addr  (the doc is wrong also)
  143. ! # VAX_COMPILER_FLT_BUG is defined for pcc which doesn't know how to 
  144. ! # convert an unsigned long into a float/double
  145.   #DEFINES= -DVAX_COMPILER_FLT_BUG -DNOSWAP
  146.   
  147. + #
  148. + # for a NeXT system, define these pre-processor symbols.
  149. + #DEFINES=-DSUN_FLT_BUG -DGENERIC_UNS_BUG 
  150. + 
  151.   CFLAGS= -O ${DEFINES} ${FEATURES} ${INCPATH}
  152.   #
  153.   # Header files
  154. ***************
  155. *** 108,121 ****
  156.   
  157.   # Source files
  158.   #
  159. ! SRCS=    ntp.c ntpd.c ntpdc.c ntpsubs.c ntp_proto.c ntp_sock.c ntp_adjust.c
  160. ! NTPDSRC= ntpd.c ntpsubs.c ntp_proto.c ntp_sock.c ntp_adjust.c
  161.   
  162.   # Object files
  163.   #
  164. ! OBJS=    ntp.o ntpd.o ntpdc.o ntpsubs.o ntp_proto.o ntp_sock.o ntp_adjust.o
  165. ! NTPDOBJ= ntpd.o ntpsubs.o ntp_proto.o ntp_sock.o ntp_adjust.o
  166.   
  167.   DIST= README Makefile man ${SRCS} ${HDRS} ntp.conf test.c extract.pl stat.pl
  168.   PROGS=    ntp ntpd ntpdc ntest
  169.   
  170. --- 119,135 ----
  171.   
  172.   # Source files
  173.   #
  174. ! NTPDSRC= ntpd.c ntpsubs.c ntp_proto.c ntp_sock.c ntp_adjust.c read_local.c \
  175. !     read_psti.c
  176. ! SRCS=    ntp.c ntpdc.c ${NTPDSRC}
  177.   
  178.   # Object files
  179.   #
  180. ! NTPDOBJ= ntpd.o ntpsubs.o ntp_proto.o ntp_sock.o ntp_adjust.o read_local.o \
  181. !     read_psti.o
  182. ! OBJS=    ntp.o ntpdc.o ${NTPDOBJ}
  183.   
  184. + 
  185.   DIST= README Makefile man ${SRCS} ${HDRS} ntp.conf test.c extract.pl stat.pl
  186.   PROGS=    ntp ntpd ntpdc ntest
  187.   
  188. ***************
  189. *** 126,133 ****
  190.       ${CC} ${LDFLAGS} -o ntp ntp.o ntpsubs.o ${LIBS}
  191.   
  192.   ntpd:    ${NTPDOBJ}
  193. !     ${CC} ${LDFLAGS} -o ntpd ntpd.o ntpsubs.o ntp_adjust.o ntp_proto.o \
  194. !         ntp_sock.o ${LIBS}
  195.   
  196.   ntpdc: ntpdc.o
  197.       ${CC} ${LDFLAGS} -o ntpdc ntpdc.o ${LIBS}
  198. --- 140,146 ----
  199.       ${CC} ${LDFLAGS} -o ntp ntp.o ntpsubs.o ${LIBS}
  200.   
  201.   ntpd:    ${NTPDOBJ}
  202. !     ${CC} ${LDFLAGS} -o ntpd ${NTPDOBJ} ${LIBS}
  203.   
  204.   ntpdc: ntpdc.o
  205.       ${CC} ${LDFLAGS} -o ntpdc ntpdc.o ${LIBS}
  206.  
  207. Index: README
  208. *** README.old    Thu May 18 18:38:20 1989
  209. --- README    Thu May 18 18:38:28 1989
  210. ***************
  211. *** 1,4 ****
  212. ! README for UNIX NTP release $Date: 89/05/03 15:08:58 $ $Revision: 3.4.1.5 $
  213.   
  214.   
  215.   
  216. --- 1,4 ----
  217. ! README for UNIX NTP release $Date: 89/05/18 12:43:58 $ $Revision: 3.4.1.6 $
  218.   
  219.   
  220.   
  221. ***************
  222. *** 36,41 ****
  223. --- 36,42 ----
  224.           VAX:    5
  225.           Sun3:    10
  226.           Sun4:    5
  227. +         NeXT:    7
  228.   
  229.           This step is optional; new algorithms will allow you to
  230.           get by (with reduced accuracy) with the system supplied
  231. ***************
  232. *** 48,53 ****
  233. --- 49,76 ----
  234.       7) Fire up ntpd in /etc/rc.local
  235.   
  236.   History:
  237. + 5/17/89
  238. +     Yet another preprocessor define for broken unsigned long to double
  239. +     conversions.  Define GENERIC_UNS_BUG, and the unsigned long is shifted
  240. +     right one bit and cast to an int before conversion to a double.  This
  241. +     seems to work much better.
  242. + 
  243. +     Preliminary support for NeXT systems.  Be sure to define both
  244. +     GENERIC_UNS_BUG and SUN_FLT_BUG.  The default value of tickadj in the
  245. +     kernel is too large so you'll have to adjust it by using the
  246. +     -t option and compiling with SETTICKADJ.  I don't think you can use
  247. +     gdb on the running /dev/mem image.   NOTE: don't even think of trying
  248. +     to run this on the 0.8 release of the system software.  You will
  249. +     utterly and absolutely hang you system.  Current testing is being 
  250. +     done on the 0.9 release.  So far, there seems to be some weirdness in
  251. +     the kernel which is attempting to sync to the clock to the internal
  252. +     clock chip every so ofter.  So while it compiles and runs, it really
  253. +     doesn't work very well on the NeXT machine.
  254. + 
  255. +     Integration of the reference clock code from Doug Kingston and Jeff 
  256. +     Schiller has been done.  To configure a reference clock, check the
  257. +     ntpd manual page.
  258. + 
  259.   5/3/89
  260.       The changes to the ntp_proto.c module for clockhopper suppression have
  261.       been tweaked once more, ever so slightly to conform with the 21 April
  262.  
  263. Index: ntp.c
  264. *** ntp.c.old    Thu May 18 18:38:44 1989
  265. --- ntp.c    Thu May 18 18:38:50 1989
  266. ***************
  267. *** 1,9 ****
  268.   #ifndef    lint
  269. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp.c,v $ $Revision: 3.4.1.5 $ $Date: 89/05/03 15:09:53 $";
  270.   #endif    lint
  271.   
  272.   /*
  273.    *  $Log:    ntp.c,v $
  274.    * Revision 3.4.1.5  89/05/03  15:09:53  louie
  275.    * Fix minor problem in ntp.c to get sin_family set in the proper place.
  276.    * 
  277. --- 1,13 ----
  278.   #ifndef    lint
  279. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp.c,v $ $Revision: 3.4.1.6 $ $Date: 89/05/18 18:21:29 $";
  280.   #endif    lint
  281.   
  282.   /*
  283.    *  $Log:    ntp.c,v $
  284. +  * Revision 3.4.1.6  89/05/18  18:21:29  louie
  285. +  * A few cosmetic changes in ntp.c for the case when udp/ntp is not in the
  286. +  * /etc/services file.
  287. +  * 
  288.    * Revision 3.4.1.5  89/05/03  15:09:53  louie
  289.    * Fix minor problem in ntp.c to get sin_family set in the proper place.
  290.    * 
  291. ***************
  292. *** 79,84 ****
  293. --- 83,89 ----
  294.    */
  295.   
  296.   #include <stdio.h>
  297. + #include <sys/types.h>
  298.   #include <sys/param.h>
  299.   #include <sys/time.h>
  300.   #include <sys/uio.h>
  301. ***************
  302. *** 136,142 ****
  303.       double t1, t2, t3, t4, offset, delay;
  304.       char ref_clock[5];
  305.       time_t net_time;
  306. !     ref_clock[4] = NULL;
  307.   
  308.       timeout.tv_sec = TIME_OUT;
  309.       timeout.tv_usec = 0;
  310. --- 141,147 ----
  311.       double t1, t2, t3, t4, offset, delay;
  312.       char ref_clock[5];
  313.       time_t net_time;
  314. !     ref_clock[4] = '\0';
  315.   
  316.       timeout.tv_sec = TIME_OUT;
  317.       timeout.tv_usec = 0;
  318. ***************
  319. *** 144,150 ****
  320.   
  321.       sp = getservbyname("ntp", "udp");
  322.       if (sp == NULL) {
  323. !         fprintf(stderr, "udp/ntp: service unknown\nUsing default %d\n",
  324.               NTP_PORT);
  325.           dst.sin_port = htons(NTP_PORT);
  326.       } else
  327. --- 149,155 ----
  328.   
  329.       sp = getservbyname("ntp", "udp");
  330.       if (sp == NULL) {
  331. !         fprintf(stderr, "udp/ntp: service unknown; using default %d\n",
  332.               NTP_PORT);
  333.           dst.sin_port = htons(NTP_PORT);
  334.       } else
  335.  
  336. Index: ntp.h
  337. *** ntp.h.old    Thu May 18 18:39:13 1989
  338. --- ntp.h    Thu May 18 18:39:19 1989
  339. ***************
  340. *** 1,7 ****
  341. ! /* $Source: /usr/users/louie/ntp/RCS/ntp.h,v $ $Revision: 3.4.1.6 $ $Date: 89/05/03 15:11:06 $ */
  342.   
  343.   /*
  344.    *  $Log:    ntp.h,v $
  345.    * Revision 3.4.1.6  89/05/03  15:11:06  louie
  346.    * Specify default file for drift value and more peer flag definitions to
  347.    * reflect various stages of clock selection critera.
  348. --- 1,10 ----
  349. ! /* $Source: /usr/users/louie/ntp/RCS/ntp.h,v $ $Revision: 3.4.1.7 $ $Date: 89/05/18 18:22:14 $ */
  350.   
  351.   /*
  352.    *  $Log:    ntp.h,v $
  353. +  * Revision 3.4.1.7  89/05/18  18:22:14  louie
  354. +  * A few extra diddles in ntp.h for the reference clock feature.
  355. +  * 
  356.    * Revision 3.4.1.6  89/05/03  15:11:06  louie
  357.    * Specify default file for drift value and more peer flag definitions to
  358.    * reflect various stages of clock selection critera.
  359. ***************
  360. *** 136,141 ****
  361. --- 139,148 ----
  362.   #define    NTP_MAXAGE    86400
  363.   #define    NTP_MAXSKW    0.01    /* seconds */
  364.   #define    NTP_MINDIST    0.02    /* seconds */
  365. + #ifdef    REFCLOCK
  366. + #define    NTP_REFMAXSKW    0.001    /* seconds (for REFCLOCKs) */
  367. + #define    NTP_REFMINDIST    0.001    /* seconds (for REFCLOCKs) */
  368. + #endif
  369.   #define    NTP_MINPOLL    6    /* (64) seconds between messages */
  370.   #define    NTP_MAXPOLL    10    /* (1024) secs to poll */
  371.   #define    NTP_WINDOW    8    /* size of shift register */
  372. ***************
  373. *** 297,302 ****
  374. --- 304,310 ----
  375.   #define    PEER_FL_CANDIDATE    0x0200    /* candidate peer */
  376.   #define    PEER_FL_SYNC        0x1000    /* peer can bet sync'd to */
  377.   #define    PEER_FL_BCAST        0x2000    /* broadcast peer */
  378. + #define    PEER_FL_REFCLOCK    0x4000    /* peer is a local reference clock */
  379.   #define    PEER_FL_SELECTED    0x8000    /* actually used by query routine */
  380.   
  381.       int    sock;            /* index into sockets to derive
  382.  
  383. Index: ntp_adjust.c
  384. *** ntp_adjust.c.old    Thu May 18 18:39:29 1989
  385. --- ntp_adjust.c    Thu May 18 18:39:32 1989
  386. ***************
  387. *** 1,5 ****
  388.   #ifndef lint
  389. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntp_adjust.c,v $ $Revision: 3.4.1.3 $ $Date: 89/04/07 18:05:17 $";
  390.   #endif
  391.   
  392.   /*
  393. --- 1,5 ----
  394.   #ifndef lint
  395. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntp_adjust.c,v $ $Revision: 3.4.1.4 $ $Date: 89/05/18 18:23:36 $";
  396.   #endif
  397.   
  398.   /*
  399. ***************
  400. *** 7,12 ****
  401. --- 7,15 ----
  402.    * 5. of the NTP specification.
  403.    *
  404.    * $Log:    ntp_adjust.c,v $
  405. +  * Revision 3.4.1.4  89/05/18  18:23:36  louie
  406. +  * A couple of changes to debug NeXT support in ntp_adjust.c
  407. +  * 
  408.    * Revision 3.4.1.3  89/04/07  18:05:17  louie
  409.    * Removed unused variable from ntp_adjust.c module.
  410.    * 
  411. ***************
  412. *** 58,63 ****
  413. --- 61,67 ----
  414.    */
  415.   
  416.   #include <stdio.h>
  417. + #include <sys/types.h>
  418.   #include <sys/param.h>
  419.   #include <sys/socket.h>
  420.   #include <sys/time.h>
  421. ***************
  422. *** 132,138 ****
  423.   adj_logical(offset)
  424.       double offset;
  425.   {
  426. !     struct timeval tv2;
  427.   #ifdef    XADJTIME2
  428.       struct timeval delta, olddelta;
  429.   #endif
  430. --- 136,142 ----
  431.   adj_logical(offset)
  432.       double offset;
  433.   {
  434. !     struct timeval tv1, tv2;
  435.   #ifdef    XADJTIME2
  436.       struct timeval delta, olddelta;
  437.   #endif
  438. ***************
  439. *** 150,158 ****
  440.           (void) gettimeofday(&tv2, (struct timezone *) 0);
  441.           steptime += tv2.tv_sec;
  442.           steptime += tv2.tv_usec / 1000000.0;
  443. !         tv2.tv_sec = steptime;
  444. !         tv2.tv_usec = (steptime - tv2.tv_sec) * 1000000;
  445. !         if (settimeofday(&tv2, (struct timezone *) 0) < 0) {
  446.               syslog(LOG_ERR, "Can't set time: %m");
  447.               return(-1);
  448.           }
  449. --- 154,169 ----
  450.           (void) gettimeofday(&tv2, (struct timezone *) 0);
  451.           steptime += tv2.tv_sec;
  452.           steptime += tv2.tv_usec / 1000000.0;
  453. !         tv1.tv_sec = steptime;
  454. !         tv1.tv_usec = (steptime - tv1.tv_sec) * 1000000;
  455. ! #ifdef    DEBUG
  456. !         if (debug > 2) {
  457. !             steptime = (tv1.tv_sec + tv1.tv_usec/1000000.0) -
  458. !                 (tv2.tv_sec + tv2.tv_usec/1000000.0);
  459. !             printf("adj_logical: %f %f\n", offset, steptime);
  460. !         }
  461. ! #endif
  462. !         if (settimeofday(&tv1, (struct timezone *) 0) < 0) {
  463.               syslog(LOG_ERR, "Can't set time: %m");
  464.               return(-1);
  465.           }
  466.  
  467. Index: ntp_proto.c
  468. *** ntp_proto.c.old    Thu May 18 18:40:21 1989
  469. --- ntp_proto.c    Thu May 18 18:40:45 1989
  470. ***************
  471. *** 1,5 ****
  472.   #ifndef    lint
  473. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp_proto.c,v $ $Revision: 3.4.1.11 $ $Date: 89/05/03 23:51:30 $";
  474.   #endif
  475.   
  476.   /*
  477. --- 1,5 ----
  478.   #ifndef    lint
  479. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntp_proto.c,v $ $Revision: 3.4.1.12 $ $Date: 89/05/18 18:25:04 $";
  480.   #endif
  481.   
  482.   /*
  483. ***************
  484. *** 11,16 ****
  485. --- 11,19 ----
  486.   
  487.   /*
  488.    * $Log:    ntp_proto.c,v $
  489. +  * Revision 3.4.1.12  89/05/18  18:25:04  louie
  490. +  * Changes for reference clock feature in ntp_proto.c
  491. +  * 
  492.    * Revision 3.4.1.11  89/05/03  23:51:30  louie
  493.    * Had my head on backwards with a reversed test in the clockhopper avoidance
  494.    * code.  Need to switch to the first selected clock when its stratum is lower
  495. ***************
  496. *** 108,113 ****
  497. --- 111,117 ----
  498.    */
  499.   
  500.   #include <stdio.h>
  501. + #include <sys/types.h>
  502.   #include <sys/param.h>
  503.   #include <sys/uio.h>
  504.   #include <sys/socket.h>
  505. ***************
  506. *** 150,157 ****
  507.   extern void make_new_peer(), double_to_s_fixed(), tstamp(), demobilize();
  508.       
  509.   
  510.   void    process_packet(), clock_update(), clear(), clock_filter(),
  511. !     select_clock(), poll_update();
  512.   
  513.   /* 3.4. Event Processing */
  514.   
  515. --- 154,165 ----
  516.   extern void make_new_peer(), double_to_s_fixed(), tstamp(), demobilize();
  517.       
  518.   
  519. + #ifdef    REFCLOCK
  520. + void    refclock_input();
  521. + #endif
  522. + 
  523.   void    process_packet(), clock_update(), clear(), clock_filter(),
  524. !     receive(), select_clock(), poll_update();
  525.   
  526.   /* 3.4. Event Processing */
  527.   
  528. ***************
  529. *** 194,200 ****
  530.   
  531.       peer->xmt = pkt->xmt;
  532.   
  533. !     if ((peer->flags & PEER_FL_BCAST) == 0) {
  534.           /* select correct socket to send reply on */
  535.           if (sendto(addrs[(peer->sock < 0 ? 0 : peer->sock)].fd,
  536.                  (char *) pkt, sizeof(ntpframe),
  537. --- 202,208 ----
  538.   
  539.       peer->xmt = pkt->xmt;
  540.   
  541. !     if ((peer->flags & (PEER_FL_BCAST|PEER_FL_REFCLOCK)) == 0) {
  542.           /* select correct socket to send reply on */
  543.           if (sendto(addrs[(peer->sock < 0 ? 0 : peer->sock)].fd,
  544.                  (char *) pkt, sizeof(ntpframe),
  545. ***************
  546. *** 203,208 ****
  547. --- 211,251 ----
  548.                      ntoa(peer->src.sin_addr));
  549.               return;
  550.           }
  551. + #ifdef    REFCLOCK
  552. +     } else if (peer->flags & PEER_FL_REFCLOCK) {
  553. +         /* Special version of code below, adjusted for refclocks */
  554. + 
  555. + 
  556. +         peer->pkt_sent++;
  557. +         i = peer->reach;    /* save a copy */
  558. + 
  559. +         peer->reach = (peer->reach << 1) & NTP_WINDOW_SHIFT_MASK;
  560. + 
  561. +         if (i && peer->reach == 0) {
  562. +             syslog(LOG_INFO, "Lost reachability with %.4s",
  563. +                    (char *)&peer->refid);
  564. + #ifdef    DEBUG
  565. +             if (debug)
  566. +                 printf("Lost reachability with %.4s\n",
  567. +                        (char *)&peer->refid);
  568. + #endif
  569. +         }
  570. + 
  571. +         if (peer->reach == 0)
  572. +             clear(peer);
  573. + 
  574. +         if (peer->valid < 2)
  575. +             peer->valid++;
  576. +         else {
  577. +             clock_filter(peer, 0.0, 0.0);    /* call with invalid values */
  578. +             select_clock();        /* and try to reselect clock */
  579. +         }
  580. + 
  581. +         peer->timer = 1<<NTP_MINPOLL;    /* poll refclocks frequently */
  582. + 
  583. +         refclock_input(peer, pkt);
  584. +         return;
  585. + #endif REFCLOCK
  586.       } else {
  587.   #ifdef    BROADCAST_NTP
  588.           if (sendto(addrs[peer->sock].fd,
  589. ***************
  590. *** 270,275 ****
  591. --- 313,353 ----
  592.           poll_update(peer, peer->hpoll + 1);
  593.   }
  594.   
  595. + #ifdef REFCLOCK
  596. + void
  597. + refclock_input(peer, pkt)
  598. +     struct ntpdata *pkt;
  599. +     struct ntp_peer *peer;
  600. + {
  601. +     struct timeval *tvp;
  602. +     struct timeval *otvp;
  603. + 
  604. +     if (read_clock(peer->sock, &tvp, &otvp))
  605. +         return;
  606. + 
  607. +     tstamp(&pkt->rec, tvp);
  608. +     pkt->xmt = pkt->rec;
  609. +     pkt->reftime = pkt->rec;
  610. +     tstamp(&pkt->org, otvp);
  611. +     peer->xmt = pkt->org;
  612. +     pkt->refid = peer->refid;
  613. +     pkt->status &= ~ALARM;
  614. +     pkt->stratum = peer->stratum;
  615. +     pkt->ppoll = 0xff;
  616. +     pkt->precision = peer->precision;
  617. +     double_to_s_fixed(&pkt->distance, 0.0);
  618. +     double_to_s_fixed(&pkt->dispersion, 0.0);
  619. + #ifdef    DEBUG
  620. +     if (debug > 5) {
  621. +         printf("\nFaking packet ");
  622. +         dump_pkt(&peer->src, pkt, (struct ntp_peer *)NULL);
  623. +     }
  624. + #endif
  625. +     receive((struct sockaddr_in *)peer, pkt, otvp, -1);
  626. +     return;
  627. + }
  628. + #endif REFCLOCK
  629. + 
  630.   /* 3.4.2. Receive Procedure */
  631.   void
  632.   receive(dst, pkt, tvp, sock)
  633. ***************
  634. *** 300,306 ****
  635.       /* if we're only going to support NTP Version 2 then this stuff
  636.          isn't necessary, right? */
  637.   
  638. !     if ((peer_mode = pkt->status & MODEMASK) == 0) {
  639.           /* packet from an older NTP implementation.  Synthesize the
  640.              correct mode.  The mapping goes like this:
  641.   
  642. --- 378,384 ----
  643.       /* if we're only going to support NTP Version 2 then this stuff
  644.          isn't necessary, right? */
  645.   
  646. !     if ((peer_mode = pkt->status & MODEMASK) == 0 && dst) {
  647.           /* packet from an older NTP implementation.  Synthesize the
  648.              correct mode.  The mapping goes like this:
  649.   
  650. ***************
  651. *** 337,342 ****
  652. --- 415,425 ----
  653.           peer->hmode = MODE_SYM_PAS;
  654.           peer->reach = 0;
  655.           clear(peer);
  656. + #ifdef    REFCLOCK
  657. +     } else if (sock == -1) {
  658. +         /* we're begin called by refclock_input(), get peer ptr */
  659. +         peer = (struct ntp_peer *)dst;
  660. + #endif
  661.       } else
  662.           peer = check_peer(dst, sock);
  663.   
  664. ***************
  665. *** 515,521 ****
  666.       delay = (t2 - t1) - (t3 - t4);
  667.       offset = ((t2 - t1) + (t3 - t4)) / 2.0;
  668.   
  669. !     delay += NTP_MAXSKW + 1.0/(unsigned long)(1L << -sys.precision);
  670.       if (peer->precision < 0 && -peer->precision < sizeof(long)*NBBY)
  671.           delay += 1.0/(unsigned long)(1L << -peer->precision);
  672.   
  673. --- 598,609 ----
  674.       delay = (t2 - t1) - (t3 - t4);
  675.       offset = ((t2 - t1) + (t3 - t4)) / 2.0;
  676.   
  677. !     delay += 1.0/(unsigned long)(1L << -sys.precision)
  678. ! #ifndef    REFCLOCK
  679. !         + NTP_MAXSKW;
  680. ! #else
  681. !         + (peer->flags&PEER_FL_REFCLOCK) ? NTP_REFMAXSKW : NTP_MAXSKW;
  682. ! #endif
  683.       if (peer->precision < 0 && -peer->precision < sizeof(long)*NBBY)
  684.           delay += 1.0/(unsigned long)(1L << -peer->precision);
  685.   
  686. ***************
  687. *** 524,530 ****
  688. --- 612,623 ----
  689.           return;
  690.       }
  691.   
  692. + #ifndef    REFCLOCK
  693.       delay = MAX(delay, NTP_MINDIST);
  694. + #else
  695. +     delay = MAX(delay, (peer->flags & PEER_FL_REFCLOCK) ?
  696. +             NTP_REFMINDIST : NTP_MINDIST);
  697. + #endif
  698.   
  699.       peer->valid = 0;
  700.       clock_filter(peer, delay, offset);  /* invoke clock filter procedure */
  701. ***************
  702. *** 531,537 ****
  703.   #ifdef    DEBUG
  704.       if (debug) {
  705.           printf("host: %s : %f : %f : %f : %f : %f : %o\n",
  706. !                ntoa(dst->sin_addr), delay, offset,
  707.                  peer->estdelay, peer->estoffset, peer->estdisp,
  708.                  peer->reach);
  709.       }
  710. --- 624,631 ----
  711.   #ifdef    DEBUG
  712.       if (debug) {
  713.           printf("host: %s : %f : %f : %f : %f : %f : %o\n",
  714. !                dst ? ntoa(dst->sin_addr) : "refclock",
  715. !                delay, offset,
  716.                  peer->estdelay, peer->estoffset, peer->estdisp,
  717.                  peer->reach);
  718.       }
  719. ***************
  720. *** 576,582 ****
  721. --- 670,690 ----
  722.            *  Update the local system variables
  723.            */
  724.           sys.leap = peer->leap;
  725. + #ifndef    REFCLOCK
  726.           sys.stratum = peer->stratum + 1;
  727. +         sys.refid = peer->src.sin_addr.s_addr;
  728. + #else
  729. +         if (peer->flags & PEER_FL_REFCLOCK) {
  730. +             /* once we re-map the stratums so that stratum 0 is
  731. +                better than stratum 1, some of this foolishness
  732. +                can go away */
  733. +             sys.stratum = peer->stratum;
  734. +             sys.refid = peer->refid;
  735. +         } else {
  736. +             sys.stratum = peer->stratum + 1;
  737. +             sys.refid = peer->src.sin_addr.s_addr;
  738. +         }
  739. + #endif
  740.   
  741.           temp = s_fixed_to_double(&peer->distance) + peer->estdelay;
  742.           double_to_s_fixed(&sys.distance, temp);
  743. ***************
  744. *** 584,590 ****
  745.           temp = s_fixed_to_double(&peer->dispersion) + peer->estdisp;
  746.           double_to_s_fixed(&sys.dispersion, temp);
  747.   
  748. -         sys.refid = peer->src.sin_addr.s_addr;
  749.           sys.reftime = peer->rec;
  750.   
  751.   #ifdef    DEBUG
  752. --- 692,697 ----
  753. ***************
  754. *** 714,719 ****
  755. --- 821,830 ----
  756.       interval = 1 << (MAX(MIN(peer->ppoll, MIN(peer->hpoll, NTP_MAXPOLL)),
  757.                  NTP_MINPOLL));
  758.   
  759. + #ifdef    REFCLOCK
  760. +     if (peer->flags & PEER_FL_REFCLOCK)
  761. +         interval = 1 << NTP_MINPOLL;
  762. + #endif
  763.       if (interval == peer->timer)
  764.           return;
  765.   
  766.  
  767. Index: ntp_sock.c
  768. *** ntp_sock.c.old    Thu May 18 18:41:07 1989
  769. --- ntp_sock.c    Thu May 18 18:41:09 1989
  770. ***************
  771. *** 1,9 ****
  772.   #ifndef    lint
  773. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntp_sock.c,v $ $Revision: 3.4.1.2 $ $Date: 89/04/07 19:07:46 $";
  774.   #endif
  775.   
  776.   /*
  777.    * $Log:    ntp_sock.c,v $
  778.    * Revision 3.4.1.2  89/04/07  19:07:46  louie
  779.    * Deleted unused variables in ntp_sock.c
  780.    * 
  781. --- 1,16 ----
  782.   #ifndef    lint
  783. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntp_sock.c,v $ $Revision: 3.4.1.3 $ $Date: 89/05/18 18:28:20 $";
  784.   #endif
  785.   
  786.   /*
  787.    * $Log:    ntp_sock.c,v $
  788. +  * Revision 3.4.1.3  89/05/18  18:28:20  louie
  789. +  * In ntp_sock.c, change the order that the bind() call is done for each socket.
  790. +  * It turns out that if you have the Multicast code installed, incoming packets
  791. +  * will be delived to the *first* socket that matches.  It also turns out that
  792. +  * when binding sockets, the first one bound is the last on checked, so we want
  793. +  * to bind the wildcard socket first.
  794. +  * 
  795.    * Revision 3.4.1.2  89/04/07  19:07:46  louie
  796.    * Deleted unused variables in ntp_sock.c
  797.    * 
  798. ***************
  799. *** 38,43 ****
  800. --- 45,51 ----
  801.    * 
  802.    */
  803.   
  804. + #include <sys/types.h>
  805.   #include <sys/param.h>
  806.   #include <sys/ioctl.h>
  807.   #include <sys/file.h>
  808. ***************
  809. *** 261,267 ****
  810.       }
  811.       close(vs);
  812.   
  813. !     for (i = nintf - 1; i >= 0; i--) {
  814.           /* create a datagram (UDP) socket */
  815.           if ((addrs[i].fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
  816.               syslog(LOG_ERR, "socket() failed: %m");
  817. --- 269,275 ----
  818.       }
  819.       close(vs);
  820.   
  821. !     for (i = 0; i < nintf; i++) {
  822.           /* create a datagram (UDP) socket */
  823.           if ((addrs[i].fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
  824.               syslog(LOG_ERR, "socket() failed: %m");
  825. ***************
  826. *** 315,321 ****
  827.            *  is being bound anyway..
  828.            */
  829.           if (setsockopt(addrs[i].fd, SOL_SOCKET, SO_REUSEADDR,
  830. - 
  831.                      (char *)&off, sizeof(off))) {
  832.               syslog(LOG_ERR, "setsockopt SO_REUSEADDR off fails: %m");
  833.   #ifdef    TEST
  834. --- 323,328 ----
  835.  
  836. Index: ntpd.c
  837. *** ntpd.c.old    Thu May 18 18:41:45 1989
  838. --- ntpd.c    Thu May 18 18:42:02 1989
  839. ***************
  840. *** 1,9 ****
  841.   #ifndef    lint
  842. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntpd.c,v $ $Revision: 3.4.1.8 $ $Date: 89/05/03 15:16:17 $";
  843.   #endif    lint
  844.   
  845.   /*
  846.    *  $Log:    ntpd.c,v $
  847.    * Revision 3.4.1.8  89/05/03  15:16:17  louie
  848.    * Add code to save the value of the drift compensation register to a file every
  849.    * hour.  Add additional configuration file directives which can specify the same
  850. --- 1,13 ----
  851.   #ifndef    lint
  852. ! static char *rcsid = "$Source: /usr/users/louie/ntp/RCS/ntpd.c,v $ $Revision: 3.4.1.9 $ $Date: 89/05/18 18:30:17 $";
  853.   #endif    lint
  854.   
  855.   /*
  856.    *  $Log:    ntpd.c,v $
  857. +  * Revision 3.4.1.9  89/05/18  18:30:17  louie
  858. +  * Changes in ntpd.c for reference clock support.  Also, a few diddles to
  859. +  * accomodate the NeXT computer system that has a slightly different nlist.h
  860. +  * 
  861.    * Revision 3.4.1.8  89/05/03  15:16:17  louie
  862.    * Add code to save the value of the drift compensation register to a file every
  863.    * hour.  Add additional configuration file directives which can specify the same
  864. ***************
  865. *** 78,83 ****
  866. --- 82,88 ----
  867.    */
  868.   
  869.   #include <stdio.h>
  870. + #include <sys/types.h>
  871.   #include <sys/param.h>
  872.   #include <sys/uio.h>
  873.   #include <sys/socket.h>
  874. ***************
  875. *** 282,293 ****
  876.           setlogmask(LOG_UPTO(LOG_INFO));
  877.   #endif    /* LOG_DAEMON */
  878.   
  879. !     syslog(LOG_NOTICE, "%s version $Revision: 3.4.1.8 $", prog_name);
  880.       syslog(LOG_NOTICE, "patchlevel %d", PATCHLEVEL);
  881.   
  882.   #ifdef    DEBUG
  883.       if (debug)
  884. !         printf("%s version $Revision: 3.4.1.8 $ patchlevel %d\n",
  885.                  prog_name, PATCHLEVEL);
  886.   #endif
  887.       (void) setpriority(PRIO_PROCESS, 0, -10);
  888. --- 287,298 ----
  889.           setlogmask(LOG_UPTO(LOG_INFO));
  890.   #endif    /* LOG_DAEMON */
  891.   
  892. !     syslog(LOG_NOTICE, "%s version $Revision: 3.4.1.9 $", prog_name);
  893.       syslog(LOG_NOTICE, "patchlevel %d", PATCHLEVEL);
  894.   
  895.   #ifdef    DEBUG
  896.       if (debug)
  897. !         printf("%s version $Revision: 3.4.1.9 $ patchlevel %d\n",
  898.                  prog_name, PATCHLEVEL);
  899.   #endif
  900.       (void) setpriority(PRIO_PROCESS, 0, -10);
  901. ***************
  902. *** 459,465 ****
  903.       struct ntpdata *pkt;
  904.       struct ntp_peer *peer;
  905.   {
  906. -     char ref_clock[5];
  907.       struct in_addr clock_host;
  908.   
  909.       printf("Packet: [%s](%d)\n", inet_ntoa(dst->sin_addr),
  910. --- 464,469 ----
  911. ***************
  912. *** 471,479 ****
  913.       switch (pkt->stratum) {
  914.       case 0:
  915.       case 1:
  916. !         (void) strncpy(ref_clock, (char *) &pkt->refid, 4);
  917. !         ref_clock[4] = '\0';
  918. !         printf(" (%s)\n", ref_clock);
  919.           break;
  920.       default:
  921.           clock_host.s_addr = (u_long) pkt->refid;
  922. --- 475,481 ----
  923.       switch (pkt->stratum) {
  924.       case 0:
  925.       case 1:
  926. !         printf(" (%.4s)\n", (char *)&pkt->refid);
  927.           break;
  928.       default:
  929.           clock_host.s_addr = (u_long) pkt->refid;
  930. ***************
  931. *** 867,872 ****
  932. --- 869,943 ----
  933.               }
  934.               if (fscanf(fp, "%s", name) != 1)
  935.                   error = TRUE;
  936. + #ifdef REFCLOCK
  937. +             else if (name[0] == '/') {
  938. +                 int stratum, precision;
  939. +                 char clk_type[20];
  940. + 
  941. +                 if (fscanf(fp, "%4s", ref_clock) != 1) {
  942. +                     error = TRUE;
  943. +                     syslog(LOG_ERR, "reference id missing");
  944. +                     goto skipit;
  945. +                 }
  946. +                 if (fscanf(fp, "%4d", &stratum) != 1) {
  947. +                     error = TRUE;
  948. +                     syslog(LOG_ERR, "reference stratum missing");
  949. +                     goto skipit;
  950. +                 }
  951. +                 if (fscanf(fp, "%4d", &precision) != 1) {
  952. +                     error = TRUE;
  953. +                     syslog(LOG_ERR, "reference precision missing");
  954. +                     goto skipit;
  955. +                 }
  956. +                 if (fscanf(fp, "%19s", clk_type) != 1) {
  957. +                     error = TRUE;
  958. +                     syslog(LOG_ERR, "reference type missing");
  959. +                     goto skipit;
  960. +                 }
  961. + 
  962. +                 if((i = init_clock(name, clk_type)) < 0) {
  963. +                     /* If we could not initialize clock line */
  964. + #ifdef DEBUG
  965. +                     if (debug)
  966. +                         printf("Could not init reference source %s (type %s)\n",
  967. +                             name, clk_type);
  968. +                     else
  969. + #endif DEBUG
  970. +                         syslog(LOG_ERR, "Could not init reference source %s (type %s)",
  971. +                             name, clk_type);
  972. +                     error = TRUE;
  973. +                     goto skipit;
  974. +                 }
  975. +                 peer = (struct ntp_peer *)
  976. +                     malloc(sizeof(struct ntp_peer));
  977. +                 if (peer == NULL) {
  978. +                     close(i);
  979. +                     error = TRUE;
  980. +                     goto skipit;
  981. +                 }
  982. +                 make_new_peer(peer);
  983. +                 ref_clock[4] = 0;
  984. +                 (void) strncpy((char *) &peer->refid,
  985. +                         ref_clock, 4);
  986. +                 peer->flags = PEER_FL_CONFIG|PEER_FL_REFCLOCK;
  987. +                 peer->hmode = MODE_SYM_ACT;
  988. +                 peer->stopwatch = stagger;
  989. +                 stagger += (1<<CLOCK_ADJ);
  990. +                 peer->flags |= PEER_FL_SYNC;
  991. +                 peer->sock = i;
  992. +                 peer->stratum = stratum;
  993. +                 peer->precision = precision;
  994. +                 clear(peer);
  995. +                 enqueue(&peer_list, peer);
  996. +                 if (debug > 1)
  997. +                     printf("Peer %s mode %d refid %.4s stratum %d precision %d\n",
  998. +                            name,
  999. +                            peer->hmode,
  1000. +                            (char *)&peer->refid,
  1001. +                            stratum, precision);
  1002. +                 transmit(peer);    /* head start for REFCLOCK */
  1003. +             }
  1004. + #endif REFCLOCK
  1005.               else if (GetHostName(name, &sin) == 0)
  1006.                   syslog(LOG_ERR, "%s: unknown host", name);
  1007.               else {
  1008. ***************
  1009. *** 875,881 ****
  1010.                           sin.sin_addr.s_addr)
  1011.                           goto skipit;
  1012.   
  1013. !                 sin.sin_port = servp->s_port;
  1014.                   peer = check_peer(&sin, -1);
  1015.                   if (peer == NULL) {
  1016.                       peer = (struct ntp_peer *)
  1017. --- 946,956 ----
  1018.                           sin.sin_addr.s_addr)
  1019.                           goto skipit;
  1020.   
  1021. !                 if (servp)
  1022. !                     sin.sin_port = servp->s_port;
  1023. !                 else
  1024. !                     sin.sin_port = htons(NTP_PORT);
  1025. ! 
  1026.                   peer = check_peer(&sin, -1);
  1027.                   if (peer == NULL) {
  1028.                       peer = (struct ntp_peer *)
  1029. ***************
  1030. *** 952,958 ****
  1031.        *  Read saved drift compensation register value.
  1032.        */
  1033.       if ((fp = fopen(driftcomp_file, "r")) != NULL) {
  1034. !         if (fscanf(fp, "%f", &j) == 1 && j > -1.0 && j < 1.0) {
  1035.               drift_comp = j;
  1036.               syslog(LOG_INFO,
  1037.                      "Drift compensation value initialized to %f", j);
  1038. --- 1027,1033 ----
  1039.        *  Read saved drift compensation register value.
  1040.        */
  1041.       if ((fp = fopen(driftcomp_file, "r")) != NULL) {
  1042. !         if (fscanf(fp, "%lf", &j) == 1 && j > -1.0 && j < 1.0) {
  1043.               drift_comp = j;
  1044.               syslog(LOG_INFO,
  1045.                      "Drift compensation value initialized to %f", j);
  1046. ***************
  1047. *** 972,982 ****
  1048.   init_kern_vars() {
  1049.       int kmem;
  1050.       static char    *memory = "/dev/kmem";
  1051. !     static struct nlist nl[] =
  1052. !     {    {"_tickadj"},
  1053.           {"_hz"},
  1054.           {"_tick"},
  1055.           {""},
  1056.       };
  1057.       static int *kern_vars[] = {&kern_tickadj, &kern_hz, &kern_tick};
  1058.       int i;
  1059. --- 1047,1064 ----
  1060.   init_kern_vars() {
  1061.       int kmem;
  1062.       static char    *memory = "/dev/kmem";
  1063. !     static struct nlist nl[] = {
  1064. ! #ifndef    NeXT
  1065. !         {"_tickadj"},
  1066.           {"_hz"},
  1067.           {"_tick"},
  1068.           {""},
  1069. + #else
  1070. +         {{"_tickadj"}},
  1071. +         {{"_hz"}},
  1072. +         {{"_tick"}},
  1073. +         {{""}},
  1074. + #endif
  1075.       };
  1076.       static int *kern_vars[] = {&kern_tickadj, &kern_hz, &kern_tick};
  1077.       int i;
  1078. ***************
  1079. *** 997,1013 ****
  1080.   
  1081.           if ((where = nl[i].n_value) == 0) {
  1082.               syslog(LOG_ERR, "Unknown kernal var %s",
  1083. !                    nl[i].n_name);
  1084.               continue;
  1085.           }
  1086.           if (lseek(kmem, where, L_SET) == -1) {
  1087.               syslog(LOG_ERR, "lseek for %s fails: %m",
  1088. !                    nl[i].n_name);
  1089.               continue;
  1090.           }
  1091.           if (read(kmem, kern_vars[i], sizeof(int)) != sizeof(int)) {
  1092.               syslog(LOG_ERR, "read for %s fails: %m",
  1093. !                    nl[i].n_name);
  1094.               *kern_vars[i] = 0;
  1095.           }
  1096.       }
  1097. --- 1079,1111 ----
  1098.   
  1099.           if ((where = nl[i].n_value) == 0) {
  1100.               syslog(LOG_ERR, "Unknown kernal var %s",
  1101. ! #ifdef    NeXT
  1102. !                    nl[i].n_un.n_name
  1103. ! #else
  1104. !                    nl[i].n_name
  1105. ! #endif
  1106. !                    );
  1107.               continue;
  1108.           }
  1109.           if (lseek(kmem, where, L_SET) == -1) {
  1110.               syslog(LOG_ERR, "lseek for %s fails: %m",
  1111. ! #ifdef    NeXT
  1112. !                    nl[i].n_un.n_name
  1113. ! #else
  1114. !                    nl[i].n_name
  1115. ! #endif
  1116. !                    );
  1117.               continue;
  1118.           }
  1119.           if (read(kmem, kern_vars[i], sizeof(int)) != sizeof(int)) {
  1120.               syslog(LOG_ERR, "read for %s fails: %m",
  1121. ! #ifdef    NeXT
  1122. !                    nl[i].n_un.n_name
  1123. ! #else
  1124. !                    nl[i].n_name
  1125. ! #endif
  1126. !                    );
  1127. ! 
  1128.               *kern_vars[i] = 0;
  1129.           }
  1130.       }
  1131. ***************
  1132. *** 1226,1235 ****
  1133.                  drift_comp, compliance, peer_switches,
  1134.                  peer_sw_inhibited);
  1135.   
  1136. !     if (sys.peer == NULL)
  1137.           strcat(buf, " UNSYNC");
  1138. !     else {
  1139.           p = strlen(buf);
  1140.           (void) sprintf(buf + p, " off %f SYNC %s %d",
  1141.                      sys.peer->estoffset,
  1142.                      ntoa(sys.peer->src.sin_addr),
  1143. --- 1324,1341 ----
  1144.                  drift_comp, compliance, peer_switches,
  1145.                  peer_sw_inhibited);
  1146.   
  1147. !     if (sys.peer == NULL) {
  1148.           strcat(buf, " UNSYNC");
  1149. ! #ifdef    REFCLOCK
  1150. !     } else if (sys.peer->flags & PEER_FL_REFCLOCK) {
  1151.           p = strlen(buf);
  1152. +         (void) sprintf(buf + p, " off %f SYNC %.4s %d",
  1153. +                    sys.peer->estoffset,
  1154. +                    (char *)&sys.peer->refid,
  1155. +                    sys.peer->stratum);
  1156. + #endif
  1157. +     } else {
  1158. +         p = strlen(buf);
  1159.           (void) sprintf(buf + p, " off %f SYNC %s %d",
  1160.                      sys.peer->estoffset,
  1161.                      ntoa(sys.peer->src.sin_addr),
  1162. ***************
  1163. *** 1306,1309 ****
  1164. --- 1412,1471 ----
  1165.   #endif
  1166.       exit(1);
  1167.   }
  1168. + 
  1169. + #ifdef    REFCLOCK
  1170. + struct refclock {
  1171. +     int fd;
  1172. +     int (*reader)();
  1173. +     struct refclock *next;
  1174. + } *refclocks = NULL;
  1175.   
  1176. + int init_clock_local(), read_clock_local();
  1177. + #ifdef PSTI
  1178. + int init_clock_psti(), read_clock_psti();
  1179. + #endif PSTI
  1180. + 
  1181. + init_clock(name, type)
  1182. + char *name, *type;
  1183. + {
  1184. +     struct refclock *r;
  1185. +     int (*reader)();
  1186. +     int cfd;
  1187. + 
  1188. +     if (strcmp(type, "local") == 0) {
  1189. +         reader = read_clock_local;
  1190. +         cfd = init_clock_local(name);
  1191. +     }
  1192. + #ifdef PSTI
  1193. +     else if (strcmp(type, "psti") == 0) {
  1194. +         reader = read_clock_psti;
  1195. +         cfd = init_clock_psti(name);
  1196. +     }
  1197. + #endif PSTI
  1198. +     else {
  1199. +         if (debug) printf("Unknown reference type\n"); else
  1200. +         syslog(LOG_ERR, "Unknown reference clock type (%s)\n", type);
  1201. +         return(-1);
  1202. +     }
  1203. +     if (cfd >= 0) {
  1204. +         r = (struct refclock *)malloc(sizeof(struct refclock));
  1205. +         r->fd = cfd;
  1206. +         r->reader = reader;
  1207. +         r->next = refclocks;
  1208. +         refclocks = r;
  1209. +     }
  1210. +     return(cfd);
  1211. + }
  1212. + 
  1213. + read_clock(cfd, tvpp, otvpp)
  1214. + int cfd;
  1215. + struct timeval **tvpp, **otvpp;
  1216. + {
  1217. +     struct refclock *r;
  1218. + 
  1219. +     for (r = refclocks; r; r = r->next)
  1220. +         if(r->fd == cfd)
  1221. +             return((r->reader)(cfd, tvpp, otvpp));
  1222. +     return(1); /* Can't happen */
  1223. + }
  1224. + #endif
  1225.  
  1226. Index: ntpdc.c
  1227. *** ntpdc.c.old    Thu May 18 18:42:37 1989
  1228. --- ntpdc.c    Thu May 18 18:42:42 1989
  1229. ***************
  1230. *** 1,9 ****
  1231.   #ifndef    lint
  1232. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpdc.c,v $ $Revision: 3.4.1.6 $ $Date: 89/05/03 15:17:27 $";
  1233.   #endif
  1234.   
  1235.   /*
  1236.    * $Log:    ntpdc.c,v $
  1237.    * Revision 3.4.1.6  89/05/03  15:17:27  louie
  1238.    * ntpdc now will display addional peer flags which indicate how far through
  1239.    * the clock selection process a peer was considered.
  1240. --- 1,12 ----
  1241.   #ifndef    lint
  1242. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpdc.c,v $ $Revision: 3.4.1.7 $ $Date: 89/05/18 18:31:26 $";
  1243.   #endif
  1244.   
  1245.   /*
  1246.    * $Log:    ntpdc.c,v $
  1247. +  * Revision 3.4.1.7  89/05/18  18:31:26  louie
  1248. +  * A few cosmetic changes for ntpd.c
  1249. +  * 
  1250.    * Revision 3.4.1.6  89/05/03  15:17:27  louie
  1251.    * ntpdc now will display addional peer flags which indicate how far through
  1252.    * the clock selection process a peer was considered.
  1253. ***************
  1254. *** 70,75 ****
  1255. --- 73,79 ----
  1256.    * 
  1257.    */
  1258.   
  1259. + #include <sys/types.h>
  1260.   #include <sys/param.h>
  1261.   #include <signal.h>
  1262.   #include <sys/uio.h>
  1263. ***************
  1264. *** 262,268 ****
  1265.       }
  1266.       sp = getservbyname("ntp", "udp");
  1267.       if (sp == 0) {
  1268. !         fprintf(stderr,"udp/ntp: service unknown\nUsing default\n");
  1269.           watcher.sin_port = htons(NTP_PORT);
  1270.       } else
  1271.           watcher.sin_port = sp->s_port;
  1272. --- 266,273 ----
  1273.       }
  1274.       sp = getservbyname("ntp", "udp");
  1275.       if (sp == 0) {
  1276. !         fprintf(stderr,"udp/ntp: service unknown, using default %d\n",
  1277. !             NTP_PORT);
  1278.           watcher.sin_port = htons(NTP_PORT);
  1279.       } else
  1280.           watcher.sin_port = sp->s_port;
  1281. ***************
  1282. *** 324,330 ****
  1283.       struct clockinfo *n;
  1284.   {
  1285.       int i;
  1286. -     char ref_clock[5];
  1287.       struct in_addr clock_host;
  1288.       double offset[PEER_SHIFT], delay[PEER_SHIFT], dsp,del,off;
  1289.       char *cvthname();
  1290. --- 329,334 ----
  1291. ***************
  1292. *** 348,356 ****
  1293.              ntohs(n->flags),
  1294.              n->leap);
  1295.       if (n->stratum == 1 || n->stratum == 0) {
  1296. !         (void) strncpy(ref_clock, (char *) &n->refid, 4);
  1297. !         ref_clock[4] = '\0';
  1298. !         printf("Reference clock ID: %s", ref_clock);
  1299.       } else {
  1300.           clock_host.s_addr = (u_long) n->refid;
  1301.           printf("Reference clock ID: [%s]", inet_ntoa(clock_host));
  1302. --- 352,358 ----
  1303.              ntohs(n->flags),
  1304.              n->leap);
  1305.       if (n->stratum == 1 || n->stratum == 0) {
  1306. !         printf("Reference clock ID: %.4s", (char *)&n->refid);
  1307.       } else {
  1308.           clock_host.s_addr = (u_long) n->refid;
  1309.           printf("Reference clock ID: [%s]", inet_ntoa(clock_host));
  1310.  
  1311. Index: ntpsubs.c
  1312. *** ntpsubs.c.old    Thu May 18 18:42:53 1989
  1313. --- ntpsubs.c    Thu May 18 18:42:55 1989
  1314. ***************
  1315. *** 1,9 ****
  1316.   #ifndef    lint
  1317. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpsubs.c,v $ $Revision: 3.4.1.2 $ $Date: 89/03/29 12:46:02 $";
  1318.   #endif    lint
  1319.   
  1320.   /*
  1321.    *  $Log:    ntpsubs.c,v $
  1322.    * Revision 3.4.1.2  89/03/29  12:46:02  louie
  1323.    * Check for success sending query before trying to listen for answers.  Will 
  1324.    * catch case of no server running and an ICMP port unreachable being returned.
  1325. --- 1,17 ----
  1326.   #ifndef    lint
  1327. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/ntpsubs.c,v $ $Revision: 3.4.1.3 $ $Date: 89/05/18 18:33:50 $";
  1328.   #endif    lint
  1329.   
  1330.   /*
  1331.    *  $Log:    ntpsubs.c,v $
  1332. +  * Revision 3.4.1.3  89/05/18  18:33:50  louie
  1333. +  * Added support few a new type of unsigned long to double compiler brokenness,
  1334. +  * called GENERIC_UNS_BUG.  If this is defined, then the unsigned long is
  1335. +  * shifted right one bit, the high-order bit of the result is cleared, then
  1336. +  * converted to a double.  The double is multiplied by 2.0, and the a 1.0 is
  1337. +  * optionall added to it if the low order bit of the original unsigned long
  1338. +  * was set.  Whew!
  1339. +  * 
  1340.    * Revision 3.4.1.2  89/03/29  12:46:02  louie
  1341.    * Check for success sending query before trying to listen for answers.  Will 
  1342.    * catch case of no server running and an ICMP port unreachable being returned.
  1343. ***************
  1344. *** 35,40 ****
  1345. --- 43,49 ----
  1346.    */
  1347.   
  1348.   #include <stdio.h>
  1349. + #include <sys/types.h>
  1350.   #include <sys/param.h>
  1351.   #include <sys/time.h>
  1352.   #include <sys/uio.h>
  1353. ***************
  1354. *** 59,65 ****
  1355. --- 68,88 ----
  1356.       struct l_fixedpt *t;
  1357.   {
  1358.       double a, b;
  1359. + #ifdef    GENERIC_UNS_BUG
  1360. +     register int i;
  1361.   
  1362. +     i = ntohl(t->fraction);
  1363. +     a = (long)((i >> 1) & 0x7fffffff);
  1364. +     a *= 2.0;
  1365. +     if (i & 1)
  1366. +         a += 1.0;
  1367. +     a = a / (4.294967296e9);    /* shift dec point over by 32 bits */
  1368. +     i = ntohl(t->int_part);
  1369. +     b = (long)((i >> 1) & 0x7fffffff);
  1370. +     b *= 2.0;
  1371. +     if (i & 1)
  1372. +         b += 1.0;
  1373. + #else    /* GENERIC_UNS_BUG */
  1374.       a = (unsigned long) ntohl(t->fraction);
  1375.   #ifdef    VAX_COMPILER_FLT_BUG
  1376.       if (a < 0.0) a += 4.294967296e9;
  1377. ***************
  1378. *** 69,81 ****
  1379.   #ifdef    VAX_COMPILER_FLT_BUG
  1380.       if (b < 0.0) b += 4.294967296e9;
  1381.   #endif
  1382. !     a += b;    /* add rest of integer part */
  1383. !     return (a);
  1384.   }
  1385.   
  1386.   /*
  1387.    *  Here we have to worry about the high order bit being signed
  1388.    */
  1389.   double
  1390.   l_fixed_to_double(t)
  1391.       struct l_fixedpt *t;
  1392. --- 92,106 ----
  1393.   #ifdef    VAX_COMPILER_FLT_BUG
  1394.       if (b < 0.0) b += 4.294967296e9;
  1395.   #endif
  1396. ! #endif    /* GENERIC_UNS_BUG */
  1397. !     return (a + b);
  1398.   }
  1399.   
  1400.   /*
  1401.    *  Here we have to worry about the high order bit being signed
  1402.    */
  1403. + 
  1404. + #if    0
  1405.   double
  1406.   l_fixed_to_double(t)
  1407.       struct l_fixedpt *t;
  1408. ***************
  1409. *** 108,113 ****
  1410. --- 133,139 ----
  1411.       }
  1412.       return (a);
  1413.   }
  1414. + #endif
  1415.   
  1416.   /*
  1417.    *  Here we have to worry about the high order bit being signed
  1418.  
  1419. Index: read_local.c
  1420. *** read_local.c.old    Thu May 18 18:43:01 1989
  1421. --- read_local.c    Thu May 18 18:43:02 1989
  1422. ***************
  1423. *** 0 ****
  1424. --- 1,30 ----
  1425. + #ifdef    REFCLOCK
  1426. + /*
  1427. +  *  A dummy clock reading routine that reads the current system time.
  1428. +  *  from the local host.  Its possible that this could be actually used
  1429. +  *  if the system was in fact a very accurate time keeper (a true real-time
  1430. +  *  system with good crystal clock or better).
  1431. +  */
  1432. + 
  1433. + #include <sys/types.h>
  1434. + #include <sys/time.h>
  1435. + 
  1436. + init_clock_local(file)
  1437. + char *file;
  1438. + {
  1439. +     return getdtablesize();    /* invalid if we ever use it */
  1440. + }
  1441. + 
  1442. + read_clock_local(cfd, tvp, mtvp)
  1443. + int cfd;
  1444. + struct timeval **tvp, **mtvp;
  1445. + {
  1446. +     static struct timeval realtime, mytime;
  1447. + 
  1448. +     gettimeofday(&realtime, 0);
  1449. +     mytime = realtime;
  1450. +     *tvp = &realtime;
  1451. +     *mtvp = &mytime;
  1452. +     return(0);
  1453. + }
  1454. + #endif
  1455.  
  1456. Index: read_psti.c
  1457. *** read_psti.c.old    Thu May 18 18:43:07 1989
  1458. --- read_psti.c    Thu May 18 18:43:09 1989
  1459. ***************
  1460. *** 0 ****
  1461. --- 1,369 ----
  1462. + #if    defined(REFCLOCK) && defined(PSTI)
  1463. + #ifndef    lint
  1464. + static char *rcsid = "$Header: /usr/users/louie/ntp/RCS/read_psti.c,v 3.4.1.1 89/05/18 18:36:45 louie Exp Locker: louie $";
  1465. + static char *sccsid = "@(#)read_psti.c    1.1    MS/ACF    89/02/17";
  1466. + #endif    lint
  1467. + 
  1468. + #define    ERR_RATE    60    /* Repeat errors once an hour */
  1469. + 
  1470. + /*
  1471. +  * read_psti.c
  1472. +  *     January 1988 -- orignal by Jeffrey I. Schiller <JIS@BITSY.MIT.EDU>
  1473. +  *     January 1989 -- QU version by Doug Kingston <DPK@Morgan.COM>
  1474. +  *
  1475. +  *   This module facilitates reading a Precision Time Standard, Inc.
  1476. +  *   WWV radio clock. We assume that clock is configured for 9600 baud,
  1477. +  *   no parity. Output is accepted in either 24 or 12 hour format.
  1478. +  *   Time is requested and processed in GMT.
  1479. +  *
  1480. +  *   This version is designed to make use of the QU command due to
  1481. +  *   additional information it provides (like date and flags).
  1482. +  *   Select is used to prevent hanging in a read when there are
  1483. +  *   no characters to read.  The line is run in cooked mode to
  1484. +  *   reduce overhead.
  1485. +  *
  1486. +  *   This requires a PSTI ROM revision later 4.01.000 or later.
  1487. +  *
  1488. +  *   Routines defined:
  1489. +  *    init_clock_psti(): Open the tty associated with the clock and
  1490. +  *               set its tty mode bits. Returns fd on success
  1491. +  *               and -1 on failure.
  1492. +  *    read_clock_psti(): Reads the clock and returns either 0 on success
  1493. +  *               or non-zero on error.  On success, pointers are
  1494. +  *               provided to the reference and local time.
  1495. +  */
  1496. + #include <stdio.h>
  1497. + #include <syslog.h>
  1498. + #include <sys/time.h>
  1499. + #include <sys/types.h>
  1500. + #include <sys/ioctl.h>
  1501. + #if defined(sun)
  1502. + #include <termio.h>
  1503. + #endif
  1504. + 
  1505. + #ifdef    DEBUG
  1506. + extern int debug;
  1507. + #endif    DEBUG
  1508. + 
  1509. + static int nerrors = 0;
  1510. + static char clockdata[32];
  1511. + #define    MIN_READ 13        /* for Rev 4.01.001 */
  1512. + 
  1513. + static double reltime();
  1514. + 
  1515. + #ifdef STANDALONE
  1516. + 
  1517. + #ifndef CLOCKDEV
  1518. + #define CLOCKDEV "/dev/radioclock"
  1519. + #endif
  1520. + 
  1521. + #define DEBUG    1
  1522. + int debug = 1;
  1523. + 
  1524. + main(argc, argv)
  1525. + int argc;
  1526. + char **argv;
  1527. + {
  1528. +     struct timeval *tvp, *otvp;
  1529. + 
  1530. +     debug = argc;
  1531. +     if (openclock(CLOCKDEV))
  1532. +         do {
  1533. +             (void)readclock(&tvp, &otvp);
  1534. +             sleep(1);
  1535. +         } while (debug>1);
  1536. +     exit(0);
  1537. + }
  1538. + #endif STANDALONE
  1539. + 
  1540. + 
  1541. + init_clock_psti(timesource)
  1542. + char *timesource;
  1543. + {
  1544. +     int cfd;
  1545. + #ifdef TCSETA
  1546. +     struct termio tty;
  1547. + #else
  1548. +     struct sgttyb tty;
  1549. + #endif
  1550. + 
  1551. +     if ((cfd = open(timesource, 2)) < 0) {
  1552. + #ifdef DEBUG
  1553. +         if (debug) perror(timesource); else
  1554. + #endif DEBUG
  1555. +         syslog(LOG_ERR, "can't open %s: %m", timesource);
  1556. +         return(-1);
  1557. +     }
  1558. + 
  1559. +     if (ioctl(cfd, TIOCEXCL, 0) < 0) {
  1560. + #ifdef DEBUG
  1561. +         if (debug) perror("TIOCEXCL on radioclock failed"); else
  1562. + #endif DEBUG
  1563. +         syslog(LOG_ERR, "TIOCEXCL on %s failed: %m", timesource);
  1564. +         return(-1);
  1565. +     }
  1566. + 
  1567. + #ifdef TCSETA
  1568. +     if (ioctl(cfd, TCGETA, &tty) < 0) {
  1569. + #ifdef DEBUG
  1570. +         if (debug) perror("ioctl on radioclock failed"); else
  1571. + #endif DEBUG
  1572. +         syslog(LOG_ERR, "ioctl on %s failed: %m", timesource);
  1573. +         return(-1);
  1574. +     }
  1575. +     tty.c_cflag = (B9600<<16)|B9600|CS8|CLOCAL|CREAD;
  1576. +     tty.c_iflag = ICRNL;
  1577. +     tty.c_oflag = 0;
  1578. +     tty.c_lflag = 0;
  1579. +     bzero((char *)tty.c_cc, sizeof tty.c_cc);
  1580. +     tty.c_cc[VMIN] = MIN_READ;
  1581. +     tty.c_cc[VTIME] = 0;
  1582. +     if (ioctl(cfd, TCSETA, &tty) < 0) {
  1583. + #else TCSETA    /* Use older Berkeley style IOCTL's */
  1584. +     bzero((char *)&tty, sizeof tty);
  1585. +     tty.sg_ispeed = tty.sg_ospeed = B9600;
  1586. +     tty.sg_flags = ANYP|CRMOD;
  1587. +     tty.sg_erase = tty.sg_kill = '\0';
  1588. +     if (ioctl(cfd, TIOCSETP, &tty) < 0) {
  1589. + #endif TCSETA
  1590. + #ifdef DEBUG
  1591. +         if (debug) perror("ioctl on radioclock failed"); else
  1592. + #endif DEBUG
  1593. +         syslog(LOG_ERR, "ioctl on %s failed: %m", timesource);
  1594. +         return(-1);
  1595. +     }
  1596. +     if (write(cfd, "xxxxxxsn\r", 9) != 9) {
  1597. + #ifdef DEBUG
  1598. +         if (debug) perror("init write to radioclock failed"); else
  1599. + #endif DEBUG
  1600. +         syslog(LOG_ERR, "init write to %s failed: %m", timesource);
  1601. +         return(-1);
  1602. +     }
  1603. +     return(cfd);            /* Succeeded in opening the clock */
  1604. + }
  1605. + 
  1606. + /*
  1607. +  * read_clock_psti() -- Read the PSTI Radio Clock.
  1608. +  */
  1609. + read_clock_psti(cfd, tvpp, otvpp)
  1610. + int cfd;
  1611. + struct timeval **tvpp, **otvpp;
  1612. + {
  1613. +     static struct timeval radiotime;
  1614. +     static struct timeval mytime;
  1615. +     struct timeval timeout;
  1616. +     struct tm *mtm;
  1617. +     struct tm radio_tm, *rtm = &radio_tm;
  1618. +     register int i;
  1619. +     register int millis;
  1620. +     register double diff;
  1621. +     int stat1, stat2;
  1622. +     fd_set readfds;
  1623. +     char message[256];
  1624. + #ifndef TCSETA
  1625. +     register char *cp;
  1626. +     int  need;
  1627. + #endif TCSETA
  1628. + 
  1629. +     FD_ZERO(&readfds);
  1630. +     FD_SET(cfd, &readfds);
  1631. +     timeout.tv_sec = 2;
  1632. +     timeout.tv_usec = 0;
  1633. + 
  1634. +     (void) ioctl(cfd, TIOCFLUSH, 0);    /* scrap the I/O queues */
  1635. + 
  1636. +     /* BEGIN TIME CRITICAL CODE SECTION!!!!!! */
  1637. +     /* EVERY CYCLE FROM THIS POINT OUT ADDS TO THE INACCURACY OF
  1638. +          THE READ CLOCK VALUE!!!!! */
  1639. +     if (write(cfd, "\003qu0000", 7) != 7) {
  1640. + #ifdef DEBUG
  1641. +         if (debug) printf("radioclock write failed\n"); else
  1642. + #endif DEBUG
  1643. +         if ((nerrors++%ERR_RATE) == 0)
  1644. +             syslog(LOG_ERR, "write to radioclock failed: %m");
  1645. +         return(1);
  1646. +     }
  1647. +     if(select(cfd+1, &readfds, 0, 0, &timeout) != 1) {
  1648. + #ifdef DEBUG
  1649. +         if (debug) printf("radioclock poll timed out\n"); else
  1650. + #endif DEBUG
  1651. +         if ((nerrors++%ERR_RATE) == 0)
  1652. +             syslog(LOG_ERR, "poll of radioclock failed: %m");
  1653. +         return(1);
  1654. +     }
  1655. +     if ((i = read(cfd, clockdata, sizeof clockdata)) < MIN_READ) {
  1656. + #ifdef DEBUG
  1657. +         if (debug) printf("radioclock read error (%d)\n", i); else
  1658. + #endif DEBUG
  1659. +         if ((nerrors++%ERR_RATE) == 0)
  1660. +             syslog(LOG_ERR, "radioclock read error (%d!=13): %m", i);
  1661. +         return(1);
  1662. +     }
  1663. + 
  1664. +     (void) gettimeofday(&mytime, (struct timezone *)0);
  1665. +     /* END OF TIME CRITICAL CODE SECTION!!!! */
  1666. + 
  1667. +     if (clockdata[i-1] != '\n') {
  1668. + #ifdef DEBUG
  1669. +         if (debug) printf("radioclock format error1 (%.12s)(0x%x)\n",
  1670. +             clockdata, clockdata[12]); else
  1671. + #endif DEBUG
  1672. +         if ((nerrors++%ERR_RATE) == 0)
  1673. +             syslog(LOG_ERR, "radioclock format error1 (%.12s)(0x%x)",
  1674. +                 clockdata, clockdata[12]);
  1675. +         return(1);
  1676. +     }
  1677. +     for (i = 0; i < 12; i++) {
  1678. +         if (clockdata[i] < '0' || clockdata[i] > 'o') {
  1679. + #ifdef DEBUG
  1680. +             if (debug) printf("radioclock format error2\n"); else
  1681. + #endif DEBUG
  1682. +             if ((nerrors++%ERR_RATE) == 0)
  1683. +                 syslog(LOG_ERR, "radioclock format error2\n");
  1684. +             return(1);
  1685. +         }
  1686. +     }
  1687. +     stat1 = clockdata[0]-'0';
  1688. +     stat2 = clockdata[1]-'0';
  1689. +     millis = ((clockdata[2]-'0')*64)+(clockdata[3]-'0');
  1690. +     rtm->tm_sec = (clockdata[4]-'0');
  1691. +     rtm->tm_min = (clockdata[5]-'0');
  1692. +     rtm->tm_hour = (clockdata[6]-'0');
  1693. +     rtm->tm_yday = ((clockdata[7]-'0')*64)+(clockdata[8]-'0')-1;
  1694. +     rtm->tm_year = 86+(clockdata[9]-'0');
  1695. +     /* byte 10 and 11 reserved */
  1696. + 
  1697. +     /*
  1698. +      * Correct "hours" based on whether or not AM/PM mode is enabled.
  1699. +      * If clock is in 24 hour (military) mode then no correction is
  1700. +      * needed.
  1701. +      */
  1702. +     if(stat2&0x10) {        /* Map AM/PM time to Military */
  1703. +         if (stat2&0x8) {
  1704. +             if (rtm->tm_hour != 12) rtm->tm_hour += 12;
  1705. +         } else {
  1706. +             if (rtm->tm_hour == 12) rtm->tm_hour = 0;
  1707. +         }
  1708. +     }
  1709. + 
  1710. +     if (stat1 != 0x4 && (nerrors++%ERR_RATE)==0) {
  1711. + #ifdef DEBUG
  1712. +         if (debug) printf("radioclock fault #%d 0x%x:%s%s%s%s%s%s\n",
  1713. +             nerrors, stat1,
  1714. +             stat1&0x20?" Out of Spec,":"",
  1715. +             stat1&0x10?" Hardware Fault,":"",
  1716. +             stat1&0x8?" Signal Fault,":"",
  1717. +             stat1&0x4?" Time Avail,":"",
  1718. +             stat1&0x2?" Year Mismatch,":"",
  1719. +             stat1&0x1?" Clock Reset,":"");
  1720. +         else {
  1721. + #endif DEBUG
  1722. +             sprintf(message, "radioclock fault #%d 0x%x:%s%s%s%s%s%s\n",
  1723. +                 nerrors, stat1,
  1724. +                 stat1&0x20?" Out of Spec,":"",
  1725. +                 stat1&0x10?" Hardware Fault,":"",
  1726. +                 stat1&0x8?" Signal Fault,":"",
  1727. +                 stat1&0x4?" Time Avail,":"",
  1728. +                 stat1&0x2?" Year Mismatch,":"",
  1729. +                 stat1&0x1?" Clock Reset,":"");
  1730. +             syslog(LOG_ERR, message);
  1731. +         }
  1732. +     }
  1733. +     if (stat1&0x38) /* Out of Spec, Hardware Fault, Signal Fault */
  1734. +         return(1);
  1735. +     if ((millis > 999 || rtm->tm_sec > 60 || rtm->tm_min > 60 ||
  1736. +          rtm->tm_hour > 23 || rtm->tm_yday > 365) && (nerrors++%ERR_RATE)==0) {
  1737. + #ifdef DEBUG
  1738. +         if (debug) printf("radioclock bogon #%d: %dd %dh %dm %ds %dms\n",
  1739. +             nerrors, rtm->tm_yday, rtm->tm_hour,
  1740. +             rtm->tm_min, rtm->tm_sec, millis);
  1741. +         else
  1742. + #endif DEBUG
  1743. +         sprintf(message, "radioclock bogon #%d: %dd %dh %dm %ds %dms\n",
  1744. +             nerrors, rtm->tm_yday, rtm->tm_hour,
  1745. +             rtm->tm_min, rtm->tm_sec, millis);
  1746. +         syslog(LOG_ERR, message);
  1747. +         return(1);
  1748. +     }
  1749. + 
  1750. +     mtm = gmtime(&mytime.tv_sec);
  1751. +     diff =  reltime(rtm, millis*1000) - reltime(mtm, mytime.tv_usec);
  1752. + #ifdef DEBUG
  1753. +     if (debug > 1)
  1754. +         printf("Clock time:  19%d day %03d %02d:%02d:%02d.%03d diff %.3f\n",
  1755. +             rtm->tm_year, rtm->tm_yday, rtm->tm_hour,
  1756. +             rtm->tm_min, rtm->tm_sec, millis, diff);
  1757. + #endif DEBUG
  1758. +     
  1759. +     if (diff > (90*24*60*60.0) && (nerrors++%ERR_RATE)==0) {
  1760. + #ifdef DEBUG
  1761. +         if (debug)
  1762. +             printf("offset excessive (system 19%d/%d, clock 19%d/%d)\n",
  1763. +                 mtm->tm_year, mtm->tm_yday,
  1764. +                 rtm->tm_year, mtm->tm_yday);
  1765. +         else
  1766. + #endif DEBUG
  1767. +         syslog(LOG_ERR, "offset excessive (system 19%d/%d, clock 19%d/%d)\n",
  1768. +                 mtm->tm_year, mtm->tm_yday,
  1769. +                 rtm->tm_year, mtm->tm_yday);
  1770. +         return(1);
  1771. +     }
  1772. + 
  1773. +     diff += (double)mytime.tv_sec + ((double)mytime.tv_usec/1000000.0);
  1774. +     radiotime.tv_sec = diff;
  1775. +     radiotime.tv_usec = (diff - (double)radiotime.tv_sec) * 1000000;
  1776. + #ifdef DEBUG
  1777. +     if (debug > 1) {
  1778. +         printf("System time: 19%d day %03d %02d:%02d:%02d.%03d\n",
  1779. +             mtm->tm_year, mtm->tm_yday, mtm->tm_hour,
  1780. +             mtm->tm_min, mtm->tm_sec, mytime.tv_usec/1000);
  1781. +         printf("stat1 0%o, stat2 0%o: ", stat1, stat2);
  1782. +         if (stat1 || stat2)
  1783. +             printf("%s%s%s%s%s%s%s%s%s%s%s%s",
  1784. +                 stat1&0x20?" Out of Spec,":"",
  1785. +                 stat1&0x10?" Hardware Fault,":"",
  1786. +                 stat1&0x8?" Signal Fault,":"",
  1787. +                 stat1&0x4?" Time Avail,":"",
  1788. +                 stat1&0x2?" Year Mismatch,":"",
  1789. +                 stat1&0x1?" Clock Reset,":"",
  1790. +                 stat2&0x20?" DST on,":"",
  1791. +                 stat2&0x10?" 12hr mode,":"",
  1792. +                 stat2&0x8?" PM,":"",
  1793. +                 stat2&0x4?" Spare?,":"",
  1794. +                 stat2&0x2?" DST??? +1,":"",
  1795. +                 stat2&0x1?" DST??? -1,":"");
  1796. +         printf("\n");
  1797. +     }
  1798. + #endif DEBUG
  1799. +     /* If necessary, acknowledge "Clock Reset" flag bit */
  1800. +     if (stat1 & 0x1) {
  1801. +         if (write(cfd, "si0", 3) != 3) {
  1802. + #ifdef DEBUG
  1803. +             if (debug) printf("radioclock reset write failed\n"); else
  1804. + #endif DEBUG
  1805. +             syslog(LOG_ERR, "reset write to radioclock failed: %m");
  1806. +             return(1);
  1807. +         }
  1808. +     }
  1809. +     if (nerrors && stat1==0x4) {
  1810. +         syslog(LOG_ERR, "radioclock OK (after %d errors)", nerrors);
  1811. +         nerrors = 0;
  1812. +     }
  1813. +     *tvpp = &radiotime;
  1814. +     *otvpp = &mytime;
  1815. +     return(0);
  1816. + }
  1817. + 
  1818. + static double
  1819. + reltime(tm, usec)
  1820. + register struct tm *tm;
  1821. + register int usec;
  1822. + {
  1823. +     return(tm->tm_year*(366.0*24.0*60.0*60.0) +
  1824. +            tm->tm_yday*(24.0*60.0*60.0) +
  1825. +            tm->tm_hour*(60.0*60.0) +
  1826. +            tm->tm_min*(60.0) +
  1827. +            tm->tm_sec +
  1828. +            usec/1000000.0);
  1829. + }
  1830. + #endif
  1831.  
  1832. Index: test.c
  1833. *** test.c.old    Thu May 18 18:43:20 1989
  1834. --- test.c    Thu May 18 18:43:22 1989
  1835. ***************
  1836. *** 1,9 ****
  1837.   #ifndef    lint
  1838. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/test.c,v $ $Revision: 3.4.1.3 $ $Date: 89/04/07 19:10:41 $";
  1839.   #endif
  1840.   
  1841.   /*
  1842.    * $Log:    test.c,v $
  1843.    * Revision 3.4.1.3  89/04/07  19:10:41  louie
  1844.    * Add check for SUN_FLT_BUG problem in test.c
  1845.    * 
  1846. --- 1,12 ----
  1847.   #ifndef    lint
  1848. ! static char *RCSid = "$Source: /usr/users/louie/ntp/RCS/test.c,v $ $Revision: 3.4.1.4 $ $Date: 89/05/18 18:37:39 $";
  1849.   #endif
  1850.   
  1851.   /*
  1852.    * $Log:    test.c,v $
  1853. +  * Revision 3.4.1.4  89/05/18  18:37:39  louie
  1854. +  * Add test for GENERIC_UNS_BUG to test.c
  1855. +  * 
  1856.    * Revision 3.4.1.3  89/04/07  19:10:41  louie
  1857.    * Add check for SUN_FLT_BUG problem in test.c
  1858.    * 
  1859. ***************
  1860. *** 95,101 ****
  1861. --- 98,106 ----
  1862.           printf(" %4.2f ", value[i]);
  1863.           double_to_l_fixed(&sample, value[i]);
  1864.           printf(" x%#8X.%#8X ", sample.int_part, sample.fraction);
  1865. + #if    0
  1866.           printf(" %4.2f", l_fixed_to_double(&sample));
  1867. + #endif
  1868.           printf("\t");
  1869.           double_to_s_fixed(&s_sample, value[i]);
  1870.           printf(" x%#4X.%#4X ", s_sample.int_part, s_sample.fraction);
  1871. ***************
  1872. *** 126,139 ****
  1873.       unsigned long ul = 0x80000001;
  1874.       double dbl;
  1875.   
  1876.       dbl = ul;
  1877.   #ifdef    VAX_COMPILER_FLT_BUG
  1878.       if (dbl < 0.0) dbl += 4.294967296e9;
  1879.   #endif
  1880.       if (dbl != 2147483649.0) {
  1881.           printf("test3 fails: can't convert from unsigned long to float\n");
  1882.           printf("             (%lu != %15g)\n", ul, dbl);
  1883. !         printf("Try defining VAX_COMPILER_FLT_BUG in the Makefile.\n");
  1884.           return 1;
  1885.       } else {
  1886.           if (v)
  1887. --- 131,156 ----
  1888.       unsigned long ul = 0x80000001;
  1889.       double dbl;
  1890.   
  1891. + #ifdef    GENERIC_UNS_BUG
  1892. +     /*
  1893. +      *  Hopefully, we can avoid the unsigned issue altogether.  Make sure
  1894. +      *  that the high-order (sign) bit is zero, and fiddle from there 
  1895. +      */
  1896. +     dbl = (long)((ul >> 1) & 0x7fffffff);
  1897. +     dbl *= 2.0;
  1898. +     if (ul & 1)
  1899. +         dbl += 1.0;
  1900. + #else
  1901.       dbl = ul;
  1902.   #ifdef    VAX_COMPILER_FLT_BUG
  1903.       if (dbl < 0.0) dbl += 4.294967296e9;
  1904.   #endif
  1905. + #endif
  1906.       if (dbl != 2147483649.0) {
  1907.           printf("test3 fails: can't convert from unsigned long to float\n");
  1908.           printf("             (%lu != %15g)\n", ul, dbl);
  1909. !         printf(
  1910. !   "Try defining VAX_COMPILER_FLT_BUG or GENERIC_UNS_BUG in the Makefile.\n");
  1911.           return 1;
  1912.       } else {
  1913.           if (v)
  1914.